package com.example.mq.common;

import com.example.mq.mqserver.core.BasicProperties;

import java.io.IOException;

// 函数式接口
@FunctionalInterface
public interface Consumer {
    // 消费者自定义的回调方法
    void handleDelivery(String consumerTag, BasicProperties basicProperties, byte[] body) throws MQException, IOException;
}
